package com.songshuai.webapi.logs.mqchannel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
/**
 * Created by yubo on 2018/12/11.
 */
public interface InputSource {
    //切面请求、结果日志
    final  String PERMISSIONSCHANNEL = "permissonchannel";
    //自定义日志断点
    final String CUSTPERMISSONCHANNEL="custpermissonchannel";

    final String LOGINCHANNEL="loginchannel";

    final  String REPLYCHANNEL = "replychannel";

    @Input("permissonchannel")
    SubscribableChannel ordersInput();

    @Input("custpermissonchannel")
    SubscribableChannel custpermissonchannelOutput();

    @Input("loginchannel")
    SubscribableChannel loginInput();

    @Output("replychannel")
    MessageChannel replyOutput();
}
